package org.apache.flink

import org.apache.flink.api.common.functions.RichFilterFunction
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode

class TableFilter extends RichFilterFunction[ObjectNode] {
    override def filter(value: ObjectNode): Boolean = {
        val tableName: String = value.get("value").get("table").asText()
        tableName.equals("student")
    }
}
